package com.sunday.common.mq.kafka.study.spring.e13_Serialization_Deserialization_Message_Conversion_Topic;

import lombok.extern.slf4j.Slf4j;
import org.springframework.kafka.annotation.KafkaHandler;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

@Slf4j
@Component
@KafkaListener(
        id = "myId_8",
        topics = {"topic8", "topic7", "topic1", "topic0"},
        clientIdPrefix = "TEST8"
)
public class MultiListenerBean {

    @KafkaHandler
    public void listen(byte[] byteArr) {
        log.info("[byte[]] : {}", byteArr);
    }

    @KafkaHandler
    public void listen(String foo) {
        log.info("[String] : {}", foo);
    }

}
